package com.ruoyi.iot.domain.vo;

import lombok.Data;

import java.util.Map;


/**
 * KuiperSQL对象
 *
 * @author Howe
 * @since 2025/7/19 11:42
 **/
@Data
public class KuiperSqlObject {

    /**
     * 流名称
     */
    private String streamName;
    /**
     * 属性Map
     */
    private Map<String , String> attributeMap;
    /**
     * 数据来源
     */
    private String dataSource;
    /**
     * 流格式 默认值：json
     */
    private String format;
    /**
     * 流主键（里面放事件ID）
     */
    private String key;

    /**
     * 监听标题
     */
    private String topicTitle;

    /**
     * 格式设置默认值：json
     *
     * @return 格式
     * @author Howe
     * @since 2025/7/19 11:43
     **/
    public String getFormat() {
        if ("".equals(format) || format == null) {
            return "json";
        }
        return format;
    }

}